package com.bw.utils;

import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

public class ClickHouseUtil1<T> extends RichSinkFunction<T> {
    @Override
    public void open(Configuration parameters) throws Exception {
        // 获取连接
    }

    @Override
    public void invoke(T value, SinkFunction.Context context) throws Exception {
        // 直接
    }

    @Override
    public void close() throws Exception {
        // 关闭
    }
}